import logging
from packages.engine.core import Execution
from packages.engine.flow_interceptor import FlowInterceptor


class GlobalSendMessageInterceptor(FlowInterceptor):
    def intercept(self, execution: Execution):
        for task in execution.processTaskList:
            logging.debug(f"全局拦截器：{task.taskName},{task.displayName}")
